package com.siteseat.crudeq.kernel;

import java.util.Set;

/**

 */
public interface QueueListenerManager extends QueueListener {

  void subscribe( Integer queueId, QueueListener listener ) throws InterruptedException;
  
  void subscribe( Set<Integer> queueIds, QueueListener listener ) throws InterruptedException;
  
  boolean unsubscribe( Integer queueId, QueueListener listener ) throws InterruptedException;
  
  void unsubscribe( Set<Integer> queueIds, QueueListener listener ) throws InterruptedException;
  
}
